const mysql = require('mysql')
const pool = mysql.createPool({
  host     :  'testmysql.haha.com',
  user     :  'xiaonuo',
  password :  'mP7hcbRBpNvj3r7U',
  database :  'jfinal_demo'
})

let query = function( sql, values ) {
  return new Promise(( resolve, reject ) => {
    pool.getConnection(function(err, connection) {
        if(err){    
            //连接失败
            console.log("reject1");
            reject( err )
        }else{  
            //连接成功进入CRUD
            connection.query(sql, values, ( err, rows) => {
                if(err){    
                    //CRUD出错
                    console.log("reject2");
                    reject(err)
                }else{  
                    //CRUD成功
                    console.log("resolve");
                    resolve(rows)
                }
                //一个事件就有一个从开始到结束的过程，数据库会话操作执行完后，就需要关闭掉，以免占用连接资源。
                connection.release()
            })
        }
    })
  })
}

module.exports = {query}